#ifndef __APP_MQTT_H
#define __APP_MQTT_H
// 定义常量
#define ADDRESS     "tcp://192.168.44.45:1883" // MQTT代理服务器的地址
#define CLIENTID    "cae37ae6-fa46-4899-8ab8-7d9ea46eed17"     // 客户端标识符
#define PUSH_TOPIC       "51car_status"                       // 发布的主题 
#define PULL_TOPIC       "51car_remote"                        // 订阅的主题
#define QOS         0                                     // 消息服务质量等级
#define TIMEOUT     10000L                                // 等待完成超时时间，单位是毫秒

int app_mqtt_init(void);



int app_mqtt_send(char *payload,int  payload_len);


int app_mqtt_registerReceive(int (*reve_callbake)(char *payload,int  payload_len));

void app_mqtt_close(void);


#endif